package com.camemax.amqp.service.impl;

import com.camemax.amqp.service.RabbitmqConsumerService;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
@RabbitListener( queues = {"wechat-queue"})
public class WechatConsumerServiceImpl implements RabbitmqConsumerService {
    @RabbitHandler
    @Override
    public void consumer(String message) {
        System.out.println("wechat accepts message => "+ message);
    }
}
